package com.bw.app.bean1;

import org.apache.flink.api.java.functions.KeySelector;
import org.apache.flink.api.java.tuple.Tuple4;

/**
 * @projectName: Flinkgd
 * @fileName: ShopPopularityKeySelector
 * @packageName: com.bw.app.bean1
 * @date: 2025/9/24 9:04
 * @author: ymw
 */
public class ShopPopularityKeySelector implements KeySelector<DwsUserBehaviorbean, Tuple4<String, String, String, String>> {
    @Override
    public Tuple4<String, String, String, String> getKey(DwsUserBehaviorbean value) throws Exception {
        return Tuple4.of(value.getShop_id(),
                value.getSku_id(),
                value.getBehavior_type(),
                value.getCh());
    }
}
